--drop table if exists d006;
--创建外部表
create external table if not exists dongfeng.navinfo_stage_d006 (
        latitude                                          INT                 COMMENT '纬度',
        longitude                                         INT                 COMMENT '经度',
        originalLat                                       INT                 COMMENT '原始纬度',
        originalLng                                       INT                 COMMENT '原始经度',
        height                                            INT                 COMMENT '高程',
        direction                                         INT                 COMMENT '方向',
        gpsDate                                           BIGINT              COMMENT '时间',
        maintenanceEvent1                                 STRING              COMMENT '维修事件ID1信息',
        maintenanceEvent2                                 STRING              COMMENT '维修事件ID2信息',
        maintenanceEvent3                                 STRING              COMMENT '维修事件ID3信息',
        terminalId                                        BIGINT              COMMENT '终端号',
        serialNumber                                      INT                 COMMENT '序列号',
        maintenanceEvent6                                 STRING              COMMENT '维修事件ID6信息',
        maintenanceEventE0                                STRING              COMMENT '维修事件IDE0信息-货箱监控报警信息',
        maintenanceEventF0                                STRING              COMMENT '维修事件IDF0信息-燃油防盗信息',
        cargoBoxTemperature1                              int              comment '货箱温度1（厢前）    ',
        cargoBoxTemperature2                              int              comment '货箱温度2（厢中）    ',
        cargoBoxTemperature3                              int              comment '货箱温度3（厢后）    ',
        cargoBoxTemperature4                              int              comment '货箱温度4（厢后回风）',
        containerHumidity1                                int               comment '货箱湿度1（厢前）    ',
        containerHumidity2                                int               comment '货箱湿度2（厢中）    ',
        containerHumidity3                                int               comment '货箱湿度3（厢后）    ',
        containerHumidity4                                int               comment '货箱湿度4（厢后回风）',
        cargoBoxDoorStatus1                               int               comment '货箱车门状态1（左侧）',
        cargoBoxDoorStatus2                               int               comment '货箱车门状态2（右侧）',
        cargoBoxDoorStatus3                               int               comment '货箱车门状态3（后门）',
        part_time                                         INT                 COMMENT '分区时间',
		hashtid                                           INT
) row format delimited fields terminated by '\001' STORED AS TEXTFILE location '/user/data/dongfeng/stage_import_d006';

--创建目标表
create table if not exists dongfeng.navinfo_parquet_d006(
        latitude                                          INT                 COMMENT '纬度',
        longitude                                         INT                 COMMENT '经度',
        originalLat                                       INT                 COMMENT '原始纬度',
        originalLng                                       INT                 COMMENT '原始经度',
        height                                            INT                 COMMENT '高程',
        direction                                         INT                 COMMENT '方向',
        gpsDate                                           BIGINT              COMMENT '时间',
        maintenanceEvent1                                 STRING              COMMENT '维修事件ID1信息',
        maintenanceEvent2                                 STRING              COMMENT '维修事件ID2信息',
        maintenanceEvent3                                 STRING              COMMENT '维修事件ID3信息',
        terminalId                                        BIGINT              COMMENT '终端号',
        serialNumber                                      INT                 COMMENT '序列号',
        maintenanceEvent6                                 STRING              COMMENT '维修事件ID6信息',
        maintenanceEventE0                                STRING              COMMENT '维修事件IDE0信息-货箱监控报警信息',
        maintenanceEventF0                                STRING              COMMENT '维修事件IDF0信息-燃油防盗信息',
        cargoBoxTemperature1                              int              comment '货箱温度1（厢前）    ',
        cargoBoxTemperature2                              int              comment '货箱温度2（厢中）    ',
        cargoBoxTemperature3                              int              comment '货箱温度3（厢后）    ',
        cargoBoxTemperature4                              int              comment '货箱温度4（厢后回风）',
        containerHumidity1                                int               comment '货箱湿度1（厢前）    ',
        containerHumidity2                                int               comment '货箱湿度2（厢中）    ',
        containerHumidity3                                int               comment '货箱湿度3（厢后）    ',
        containerHumidity4                                int               comment '货箱湿度4（厢后回风）',
        cargoBoxDoorStatus1                               int               comment '货箱车门状态1（左侧）',
        cargoBoxDoorStatus2                               int               comment '货箱车门状态2（右侧）',
        cargoBoxDoorStatus3                               int               comment '货箱车门状态3（后门）',
        create_time                                       STRING              COMMENT '数据创建时间'
) partitioned by (part_time int,hashtid int) stored as Parquet TBLPROPERTIES('parquet.compression'='SNAPPY');
